package com.xuecheng.base.constant;

/**
 * @author 勾新杰
 * @version 1.0
 * @description: 消息队列常量
 * @date 2025/3/8 20:11
 */
public class RabbitMQConstant {

    /**
     * 死信交换机
     */
    public static final String EXCHANGE_ERROR_DIRECT = "error.direct";

    /**
     * 支付结果通知交换机
     */
    public static final String EXCHANGE_PAY_RESULT_TOPIC = "pay.result.topic";

    /**
     * 延迟消息交换机
     */
    public static final String EXCHANGE_DELAY_DIRECT = "delay.direct";

    /**
     * 死信队列
     */
    public static final String QUEUE_ERROR = "error.queue";

    /**
     * 支付结果通知学习中心队列
     */
    public static final String QUEUE_PAY_RESULT_LEARNING = "pay.result.learning.queue";

    /**
     * 支付流水延迟队列
     */
    public static final String QUEUE_DELAY_PAY_RECORD = "delay.pay.record.queue";

    /**
     * 死信路由key
     */
    public static final String ROUTING_KEY_ERROR_DIRECT = "error";

    /**
     * 支付结果通知路由key TOPIC
     */
    public static final String ROUTING_KEY_PAY_RESULT_TOPIC = "pay.result.#";

    /**
     * 支付结果通知学习中心路由key
     */
    public static final String ROUTING_KEY_PAY_RESULT_LEARNING = "pay.result.learning";

    /**
     * 支付流水延迟路由key
     */
    public static final String ROUTING_KEY_DELAY_PAY_RECORD = "delay.pay.record";
}
